package com.spark.prepareJob.tags
import com.spark.beans.Logs
import com.spark.prepareJob.constants.AdConstants

/**
  * 3）渠道（标签格式：CNxxxx->1）xxxx为渠道ID
  * 通过频道id确定Channeid:
  */
object ChannelTags extends Tags {
  override def extractTags(log: Logs): Map[String, Int] = {
    val channelId = log.channelid
    Map[String,Int](AdConstants.AD_PREFIX_CHANNEL + channelId -> 1)
  }
}
